package com.bjtu.boatmq.common.protocol.request;

public class OffsetCommitRequest {
    String topicName;
    int partitionId;
    int haveConsumedOffset; // 消费成功的最新偏移量

    public String getTopicName() {
        return topicName;
    }

    public void setTopicName(String topicName) {
        this.topicName = topicName;
    }

    public int getPartitionId() {
        return partitionId;
    }

    public void setPartitionId(int partitionId) {
        this.partitionId = partitionId;
    }

    public int getHaveConsumedOffset() {
        return haveConsumedOffset;
    }

    public void setHaveConsumedOffset(int haveConsumeOffset) {
        this.haveConsumedOffset = haveConsumeOffset;
    }

}
